"""
事务操作：
"""
import redis
import time
client = redis.StrictRedis(password='123456')
try:
    # # 使用watch 命令监控库存键
    # client.watch('kc')
    # # 开始事务 创建一个管道对象pipeline
    # pipeline = client.pipeline()

    # 开始事务 创建一个管道对象pipeline
    pipeline = client.pipeline()

    # 使用watch 命令监控库存键
    pipeline.watch('kc')

    pipeline.multi()
    # 执行减少库存命令
    pipeline.incrby('kc', -1)
    time.sleep(20)
    # 执行事务提交
    result = pipeline.execute()
    print(result)
except redis.WatchError:
    print('事务执行失败')
# 关闭连接  释放资源
client.close()

